package drds.binlog.kafka;

import drds.binlog.common.Authors;
import drds.common.Author;
import lombok.Getter;
import lombok.Setter;

import java.util.ArrayList;
import java.util.List;

/**
 * kafka 配置项
 */
@Author(name = Authors.LI_YANG)
public class KafkaProperties
{

    @Setter
    @Getter
    private String servers = "localhost:6667";

    @Setter
    @Getter
    private int retries = 0;

    @Setter
    @Getter
    private int batchSize = 16384;

    @Setter
    @Getter
    private int lingerMs = 1;

    @Setter
    @Getter
    private long bufferMemory = 33554432L;

    @Setter
    @Getter
    private boolean filterTransactionEntry = true;

    @Setter
    @Getter
    private int canalBatchSize = 50;

    @Setter
    @Getter
    private Long getTimeout;


    @Setter
    @Getter
    private List<Destination> destinationList = new ArrayList<Destination>();


}
